package cn.lcc.utils.service;

import reactor.core.Disposable;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public interface BaseFluxService {
    Flux publishMsg();
    Disposable generateData();
    Mono generateData2();

    void unsubscribe();

}
